//package com.intramirror.msdemo.business.service.impl;
//
//import com.alibaba.fastjson.JSON;
//import com.intramirror.monitor.model.enums.MonitorMysqlDataTypeEnum;
//import com.intramirror.monitor.model.mysql.MonitorMysqlDataAdd;
//import com.intramirror.monitor.model.mysql.MonitorMysqlDataDel;
//import com.intramirror.monitor.model.mysql.MonitorMysqlDataMessage;
//import com.intramirror.monitor.model.mysql.MonitorMysqlDataUpd;
//import com.intramirror.monitor.model.util.MonitorMysqlDataUtil;
//import com.intramirror.msdemo.business.service.IMonitorMysqlTableSkuService;
//import org.springframework.stereotype.Service;
//
///**
// * @author Thomas
// * @date 2018/12/14
// * @desc
// */
//@Service("monitorMysqlTableSkuService")
//public class MonitorMysqlTableSkuServiceImpl implements IMonitorMysqlTableSkuService {
//
//    @Override
//    public Boolean handleMessage(MonitorMysqlDataMessage message) {
//        System.out.println("-------------------------------------");
//        Integer dataType = message.getDataType();
//        if(dataType.equals(MonitorMysqlDataTypeEnum.ADD.getKey())){
//            MonitorMysqlDataAdd dataAdd = MonitorMysqlDataUtil.messageData2Obj(message.getData(), MonitorMysqlDataAdd.class);
//            System.out.println(dataAdd.getDataAdd().size());
//            System.out.println(JSON.toJSONString(dataAdd));
//        } else if(dataType.equals(MonitorMysqlDataTypeEnum.UPD.getKey())){
//            MonitorMysqlDataUpd dataUpd = MonitorMysqlDataUtil.messageData2Obj(message.getData(), MonitorMysqlDataUpd.class);
//            System.out.println(dataUpd.getColumnList());
//            System.out.println(dataType);
//            System.out.println(JSON.toJSONString(dataUpd));
//        } else if(dataType.equals(MonitorMysqlDataTypeEnum.DEL.getKey())){
//            MonitorMysqlDataDel dataDel = MonitorMysqlDataUtil.messageData2Obj(message.getData(), MonitorMysqlDataDel.class);
//            System.out.println(dataDel.getDataDel().size());
//            System.out.println(JSON.toJSONString(dataDel));
//        }
//        return null;
//    }
//}
